package com.jd.jobkeeper.server.transport;

import com.jd.jobkeeper.protocals.Response;
import com.jd.jobkeeper.protocals.SetupRequest;
import com.jd.jobkeeper.protocals.Task;
import com.jd.jobkeeper.server.data.entity.JobInfo;
import reactor.core.publisher.Mono;

public interface JobServerProtocol {

    void onAcceptor(SetupRequest setupRequest);

    Mono<Response> reportTask(Task task);

    Mono<Response> testAndSet(Task task);

    Mono<Response> killTask(JobInfo jobInfo);

}
